package com.jar.exercise.多线程.AQS.reentrantlock.线程间通信;

public class Consume implements Runnable {
	private Milk milk;

	public Consume(Milk milk) {
		this.milk = milk;
	}

	@Override
	public void run() {
		for (int i = 0; i < 10; i++) {
			milk.consume();
		}
	}
}
